package com.itbaizhan.openhis.mq.service;

import com.itbaizhan.openhis.mq.dto.BaseMqDto;

public interface RocketMqService {
    /**
     * 发送消息
     * @param topic 主题
     * @param data 内容
     * @param delayLevel 延迟级别
     */
    void sendDelay(String topic, BaseMqDto<?> data, int delayLevel);
}
